3f6b909c3d4eddd1dc282ac065e90233809873f5,components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumer.java,KubernetesPodsConsumer,doStart,#,52

Before Change


        super.doStart();
        map = new ConcurrentHashMap<Long, PodEvent>();

        if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getOauthToken())) {
            if (ObjectHelper.isNotEmpty(getEndpoint().getKubernetesConfiguration().getNamespaceName())) {
                getEndpoint().getKubernetesClient().pods()
                        .inNamespace(getEndpoint().getKubernetesConfiguration().getNamespaceName())
                        .watch(new Watcher<Pod>() {

                            @Override
                            public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
                                    Pod resource) {
                                PodEvent pe = new PodEvent(action, resource);
                                map.put(System.currentTimeMillis(), pe);
                            }

                            @Override
                            public void onClose(KubernetesClientException cause) {
                                if (cause != null) {
                                    LOG.error(cause.getMessage(), cause);
                                }

                            }
                        });
            } else {
                getEndpoint().getKubernetesClient().pods().watch(new Watcher<Pod>() {

                    @Override
                    public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, Pod resource) {
                        PodEvent pe = new PodEvent(action, resource);
                        map.put(System.currentTimeMillis(), pe);
                    }

                    @Override
                    public void onClose(KubernetesClientException cause) {
                        if (cause != null) {
                            LOG.error(cause.getMessage(), cause);
                        }
                    }
                });
            }
        }
    }

After Change


    @Override
    protected void doStart() throws Exception {
        super.doStart();
        executor = getEndpoint().createExecutor();

        executor.submit(new PodsConsumerTask());
    }

    @Override